package com.talent.service.iot.controller;

import com.talent.service.iot.mqtt.service.IMqttSessionService;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;
import reactor.core.publisher.Flux;

/**
 * @ClassName：MqttController
 * @Author: hszhou
 * @Date: 2025/1/23 9:09
 * @Description: 必须描述类做什么事情, 实现什么功能
 */
@RestController
@RequestMapping("mqtt")
public class MqttController {


    @Autowired
    private IMqttSessionService mqttSessionService;

    @GetMapping("clients")
    public Flux<String> getClients(){

       return mqttSessionService.clients();

    }
}
